package com.cn.Utils;

import com.cn.entity.RunLog;

import java.util.concurrent.LinkedBlockingQueue;

/**
 * Created by chenyuncong on 2018/8/6.
 */
public class RunLogQueue {
    /**
     * 保证这个对象 唯一 且不能修改对象地址
     */
    public static final LinkedBlockingQueue<RunLog> queueCount = new LinkedBlockingQueue<>();

    public static final LinkedBlockingQueue<RunLog> queueSave = new LinkedBlockingQueue<>();

    public static void put(RunLog r){
        try {
            queueSave.put(r);
            queueCount.put(r);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
